package cn.yunyichina.provider.pay.listener;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.listener.MessageListener;

/**
 * Created by Lullaby on 2016/10/24.
 */
public class DefaultTopicListener implements MessageListener<Integer, String> {

    private static final Logger logger = LoggerFactory.getLogger(DefaultTopicListener.class);

    public void onMessage(ConsumerRecord<Integer, String> integerStringConsumerRecord) {
        logger.info("This is a default kafka topic listener.");
    }

}
